package heartbeat;/*

 */

import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;
import io.netty.handler.timeout.IdleStateEvent;

/**
 * @ClassName MyServerHandler
 * @Author Final
 * @Project DataStructures
 */
public class MyServerHandler extends ChannelInboundHandlerAdapter {

    @Override
    public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception {

        if (evt instanceof IdleStateEvent){

            IdleStateEvent event=(IdleStateEvent)evt;
            String eventType=null;
           switch (event.state()){
               case READER_IDLE:
                   eventType="读空闲";
                   break;
               case WRITER_IDLE:
                   eventType="写空闲";
                   break;
               case ALL_IDLE:
                   eventType="读写空闲";
                   break;
           }

            System.out.println(ctx.channel().remoteAddress()+"-------------------------"+eventType);
        }
    }
}
